package com.ly.integral.consumer;

import com.alibaba.fastjson.TypeReference;
import com.domain.Order;
import com.ass.rocketmq.constant.MQTopic;
import com.ass.rocketmq.consumer.AbstractConcurrencyPushConsumer;
import lombok.Getter;
import org.springframework.stereotype.Component;

@Component
public class MessageTracingTest1 extends AbstractConcurrencyPushConsumer<Order> {

    @Getter
    private final TypeReference<Order> model = new TypeReference<Order>(){};

    @Getter
    private final MQTopic mqTopic = MQTopic.MESSAGE_TRACING_TWO;

    //消息回溯的消费者 例子 大部分实现都是在rocket mq管理工具上实现的 文档上都有记录
    @Override
    protected void handler(Order model, String keys) {
        System.out.println("消息主："+model.getDate());
    }



}
